package com.gome.ocean.server.oracle.common.db.rocketmq;

import com.alibaba.rocketmq.client.producer.MQProducer;

/**
 * Gcache数据源
 * 
 * @author haqiaolong 2016年6月27日 下午5:40:38
 * @since 5.0.0
 */
public class RocketMqDataSource {

    private MQProducer     producer;

    private RocketMqConfig rocketMqConfig;

    public RocketMqDataSource(MQProducer producer, RocketMqConfig rocketMqConfig){
        super();
        this.producer = producer;
        this.rocketMqConfig = rocketMqConfig;
    }

    public MQProducer getProducer() {
        return producer;
    }

    public void setProducer(MQProducer producer) {
        this.producer = producer;
    }

    public RocketMqConfig getRocketMqConfig() {
        return rocketMqConfig;
    }

    public void setRocketMqConfig(RocketMqConfig rocketMqConfig) {
        this.rocketMqConfig = rocketMqConfig;
    }
}
